from .circuit_breaker import CircuitBreaker

class RiskManager:
    """风控工作流集成"""
    
    def __init__(self):
        self.breakers = {
            'intraday': CircuitBreaker(),
            'overnight': CircuitBreaker()
        }
        
    async def monitor(self, positions):
        """实时风控监控"""
        return {
            breaker_type: breaker.validate(positions)
            for breaker_type, breaker in self.breakers.items()
        }